type google.golang.org/grpc/internal/transport.controlBuffer
13 uses
google.golang.org/grpc/internal/transport (current package)
controlbuf.go#L312: type controlBuffer struct {
controlbuf.go#L332: func newControlBuffer(done <-chan struct{}) *controlBuffer {
controlbuf.go#L333: return &controlBuffer{
controlbuf.go#L343: func (c *controlBuffer) throttle() {
controlbuf.go#L353: func (c *controlBuffer) put(it cbItem) error {
controlbuf.go#L365: func (c *controlBuffer) executeAndPut(f func() bool, it cbItem) (bool, error) {
controlbuf.go#L409: func (c *controlBuffer) get(block bool) (any, error) {
controlbuf.go#L436: func (c *controlBuffer) getOnceLocked() (any, error) {
controlbuf.go#L459: func (c *controlBuffer) finish() {
controlbuf.go#L510: cbuf *controlBuffer
controlbuf.go#L535: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
http2_client.go#L96: controlBuf *controlBuffer
http2_server.go#L87: controlBuf *controlBuffer